d4076a41d292e7967e00f211bf6926a87a744b35,tests/frontend/org/voltcore/network/TestNIOWriteStream.java,TestNIOWriteStream,testLastWriteDelta,#,344

Before Change


        final ByteBuffer b = ByteBuffer.allocate(5);
        wstream.enqueue(b.duplicate());
        assertEquals( 5, wstream.calculatePendingWriteDelta(EstTime.currentTimeMillis() + 5));
        wstream.drainTo( channel, wstream.swapAndSerializeQueuedWrites(pool));
        assertEquals( 0, wstream.calculatePendingWriteDelta(EstTime.currentTimeMillis() + 5));

        Thread.sleep(20);

After Change


    }

    public void testLastWriteDelta() throws Exception {
        final MockChannel channel = new MockChannel(MockChannel.SINK);
        MockPort port = new MockPort();
        NIOWriteStream wstream = new NIOWriteStream(port);

        assertEquals( 0, wstream.calculatePendingWriteDelta(999));

        EstTimeUpdater.update(System.currentTimeMillis());

        /**
         * Test the basic write and drain
         */
        final ByteBuffer b = ByteBuffer.allocate(5);
        wstream.enqueue(b.duplicate());
        assertEquals( 5, wstream.calculatePendingWriteDelta(EstTime.currentTimeMillis() + 5));
        wstream.swapAndSerializeQueuedWrites(pool);
        wstream.drainTo( channel);
        assertEquals( 0, wstream.calculatePendingWriteDelta(EstTime.currentTimeMillis() + 5));

        Thread.sleep(20);